ab3f93d584560278d397767057d367191b424ed7,src/main/java/reactor/ipc/netty/channel/ChannelOperationsHandler.java,ChannelOperationsHandler,userEventTriggered,#ChannelHandlerContext#Object#,204
Before Change
log.trace("User event {}", evt);
}
if (evt == NettyPipeline.handlerTerminatedEvent()) {
parentContext().terminateChannel(ctx.channel());
return;
}
if (evt instanceof NettyPipeline.SendOptionsChangeEvent) {
After Change
final public void userEventTriggered(ChannelHandlerContext ctx, Object evt)
throws Exception {
if (log.isTraceEnabled()) {
log.trace("{} End of the pipeline, User event {}", ctx.channel(), evt);
}
if (evt == NettyPipeline.handlerTerminatedEvent()) {
ContextHandler<?> c = lastContext;
if (c == null){
if (log.isDebugEnabled()){
log.debug("{} No context to dispose", ctx.channel());
}
return;
}
if (log.isDebugEnabled()){
log.debug("{} Disposing context {}", ctx.channel(), c);
}
lastContext = null;
c.terminateChannel(ctx.channel());
return;
}
if (evt instanceof NettyPipeline.SendOptionsChangeEvent) {
if (log.isDebugEnabled()) {
log.debug("{} New sending options", ctx.channel());
}
((NettyPipeline.SendOptionsChangeEvent) evt).configurator()
.accept(this);